package com.kingstar.ceres.data.helper;

import com.kingstar.ceres.data.bo.BaseFileMapping;
import com.kingstar.ceres.data.handler.ITaskLockHandler;
import com.kingstar.ceres.data.strategy.csv.ICsvChannelManager;
import lombok.extern.slf4j.Slf4j;

//@Component
@Slf4j
public class CsvImportHelper extends AbstractFileImportHelper{

    private final ICsvChannelManager csvChannelManager;

    public CsvImportHelper(ITaskLockHandler taskLockHandler, ICsvChannelManager csvChannelManager) {
        super.taskLockHandler = taskLockHandler;
        this.csvChannelManager = csvChannelManager;
    }

    @Override
    public void doProcess(BaseFileMapping entity, String opDate) {
        csvChannelManager.process(entity,opDate);
    }
}